package cn.linjianhui.demo.flink.checkpoint;

import org.apache.flink.api.common.functions.RichFlatMapFunction;
import org.apache.flink.streaming.api.checkpoint.ListCheckpointed;
import org.apache.flink.util.Collector;

import java.util.List;

public class HighTempCounter extends RichFlatMapFunction<String, String> implements ListCheckpointed {
    @Override
    public void flatMap(String s, Collector<String> collector) throws Exception {

    }

    @Override
    public List snapshotState(long l, long l1) throws Exception {
        return null;
    }

    @Override
    public void restoreState(List list) throws Exception {

    }
}
